package operators;

import org.apache.flink.api.java.tuple.Tuple2;
import org.apache.flink.api.java.tuple.Tuple3;
import org.apache.flink.streaming.api.functions.windowing.WindowFunction;
import org.apache.flink.streaming.api.windowing.windows.TimeWindow;
import org.apache.flink.util.Collector;
import pojo.UniqueView;

import java.util.HashSet;

public class UV_ProcessWindowFunction implements WindowFunction<Tuple2<Integer, Long>, UniqueView, Integer, TimeWindow>{

    @Override
    public void apply(Integer integer, TimeWindow window, Iterable<Tuple2<Integer, Long>> input, Collector<UniqueView> out) throws Exception {
    }
}
